package com.yhy.configserver.message;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * describe:通过 stream 来操作 kafka
 *
 * @author helloworldyu
 * @date 2018/6/26
 */
public interface IStreamClient {
	@Input("myMessage")
	SubscribableChannel input();

	@Output("myMessage")
	MessageChannel output();
}
